package com.qf.rabbitmq.pubsub;


import com.qf.rabbitmq.util.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

import java.nio.charset.StandardCharsets;

/*
 * 一个生产者对应一个队列    一个队列对应一个消费者
 *  多个消费者对应一个队列是    也只是一个消费者在处理
 * */

//发送者
public class Sender {

//    声明了一个 交换机
    private static final String EXCHANGENAME="2102fanout";

    public static void main(String[] args)  {

//        获取连接
        Connection connection = ConnectionUtil.getConnection();
        try {
            //       通过连接  创建通道
            Channel  channel = connection.createChannel();
//            声明交换机
            channel.exchangeDeclare(EXCHANGENAME, "fanout");

//      发送  1交换机    2队列名字   3  附加属性  4 要发送的内容
            for (int i = 0; i < 100; i++) {
                channel.basicPublish(EXCHANGENAME,"", null, ("你在说什么啊呢"+i).getBytes(StandardCharsets.UTF_8));

            }
//        如果没有用了 关闭连接
            channel.close();
            connection.close();
        } catch (Exception e) {
            e.printStackTrace();
        }


    }
}
